package com.yunhe.transfer.service.base;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.yunhe.common.exception.ArgumentErrorException;
import com.yunhe.common.model.base.DataTransferDTO;
import com.yunhe.common.model.data.Measurement;

import java.util.List;

/**
 * @title: ReceiveDataService
 * @Author Chen Lun
 * @Date: 2021/1/20
 */
public interface DataTransferService {
    public void receiveData(List<Measurement> measurements, Long stationCode) throws JsonProcessingException;

    public void recollectData(DataTransferDTO dataTransferDTO) throws JsonProcessingException, ArgumentErrorException;

    public void recollectDataForMqtt(Long stationId, List<String> dtime) throws JsonProcessingException, ArgumentErrorException;

    public void recollectDataForWebSocket(Long stationId, List<String> dtime) throws JsonProcessingException, ArgumentErrorException;
}
